package mq_struct

import "im_sys/pkg/constants"

// ChatMsg Kafka和用户websocket之间传递的消息格式
type ChatMsg struct {
	ConversationId string             `json:"conversation_id"`
	ChatType       constants.ChatType `json:"chat_type"` // 聊天类型（群聊/私聊）
	SendId         string             `json:"send_id"`
	RecvId         string             `json:"recv_id"`
	SendTime       int64              `json:"send_time"`
	MType          constants.MType    `json:"m_type"` // 聊天消息类型（文字/图片/视频）
	Content        string             `json:"content"`
}
